# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.operators.bash import BashOperator
from jms_hi.dm.dm_centersend_warning_sum_hi import jms_dm__dm_centersend_warning_sum_hi

jms_oracle__dm_centersend_warning_sum_hi = BashOperator(
    task_id='jms_oracle__dm_centersend_warning_sum_hi',
    execution_timeout=timedelta(hours=2),
    email=['macheng@jtexpress.com','yl_bigdata@yl-scm.com'],
    bash_command="jms_hi/oracle/dm_centersend_warning_sum_hi/execute.sh",
    pool='spmi_apack',
    retries=1,
    pool_slots=2,
)
jms_oracle__dm_centersend_warning_sum_hi << [jms_dm__dm_centersend_warning_sum_hi]